package com.xtck.ha.fault.framework.kafka;


import com.xtck.ha.fault.framework.utils.JsonResult;

/**
 * @author zhoutanxin@gmail.com
 * @date 2022/10/22 16:13
 */
public interface IKafkaProducer {

    JsonResult<String> send(String topic, PushFaultMsg pushFaultMsg);

}
